package com.lvan.rabbit.producer.mode2_workquene;

import com.lvan.rabbit.utils.RabbitMQUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

import java.io.IOException;

/**
 * 任务模式：
 * 生产者直接将消息发送到队列中；
 * 可以有多个消费者消费队列中的消息；
 *
 * @author Lvan
 */
public class WorkQuene1 {

    public static void main(String[] args) throws IOException {
        // 获取连接
        Connection connection = RabbitMQUtil.getConnection();

        // 创建通道
        Channel channel = connection.createChannel();

        // 通过通道声明队列
        channel.queueDeclare("work", false, false, true, null);

        // 生产消息
        for (int i = 0; i < 30; i++) {
            channel.basicPublish("", "work", null, ("helloworld, RabbitMQ :" + i).getBytes());
        }


        // 关闭资源
        RabbitMQUtil.closeConnectionAndChanel(channel, connection);
    }
}
